//package com.trt.usercenter.rocketmq;
//
//import org.springframework.cloud.stream.annotation.Input;
//import org.springframework.cloud.stream.annotation.Output;
//import org.springframework.messaging.SubscribableChannel;
//
///**
// * SpringCloudStream自定义接口,消费消息
// */
//public interface MySink {
//
//    String MY_INPUT = "my-input";
//
//    @Input(MY_INPUT)
//    SubscribableChannel input();
//
//}
